3ee6452c83d9b94fa42f630a1047b1b89110bd2c,src/test/java/com/moilioncircle/redis/replicator/RedisReplicatorTest.java,RedisReplicatorTest,testFilter,#,320

Before Change


    public void testFilter() throws IOException, InterruptedException {
        RedisReplicator redisReplicator = new RedisReplicator(
                RedisReplicatorTest.class.getClassLoader().getResourceAsStream("dumpV7.rdb"),
                Configuration.defaultSetting().setVerbose(true));
        final AtomicInteger acc = new AtomicInteger(0);
        redisReplicator.addRdbFilter(new RdbFilter() {
            @Override

After Change


    public void testFilter() throws IOException, InterruptedException {
        RedisReplicator redisReplicator = new RedisReplicator(
                RedisReplicatorTest.class.getClassLoader().getResourceAsStream("dumpV7.rdb"),
                Configuration.defaultSetting());
        final AtomicInteger acc = new AtomicInteger(0);
        redisReplicator.addRdbFilter(new RdbFilter() {
            @Override